const express = require('express');
const app = express();
const router = require('./router/index');
const cors = require('cors');

// 跨域处理
app.use(cors());
// post请求 表单数据
app.use(express.urlencoded({ extended: true }));
// 静态资源共享
app.use(express.static('upload'))

app.use('/', router);

// websocket
const WebSocet = require('ws')
// 5000 端口
const socket = new WebSocet.Server({ port: 5000 })
socket.on('connection', function (ws) {
    let msgobj = {
        status: 1,
        msg: '您好，请问有什么可以帮到您的呢？'
    }
    ws.send(JSON.stringify(msgobj))
    ws.on('message', function (res) {
        // console.log('5000',res);
        ws.send(JSON.stringify({
            status: 1,
            msg: '我已经收到您的回复了哦~'
        }))
        // socket上面有所有的客户端连接
        // socket.clients.forEach(item => {
        //     item.send(JSON.stringify({
        //         status: 1,
        //         msg: JSON.parse(res).msg
        //     }))
        // })
    })
})

app.listen(7878, () => {
    console.log('服务器启动成功!🌍 server running at http://127.0.0.1:7878');
})